package com.dmbjz.moddymq.service;


import com.dmbjz.moddymq.po.TransMessagePO;

import java.util.List;

public interface TransMessageService {


    /* 发送前暂存消息 */
    TransMessagePO messageSendReady(String id,String exchange, String routingKey, String body);


    /**
     * 设置消息发送成功
     *
     * @param id 消息ID
     */
    void messageSendSuccess(String id);


    /* 设置消息返回 */
    TransMessagePO messageSendReturn(String id, String exchange, String routingKey, String body);


    /* 查询应发未发消息 */
    List<TransMessagePO> listReadyMessages();


    /**
     * 记录消息发送次数
     * @param id id
     */
    void messageResend(String id);


    /**
     * 消息重发多次，放弃
     * @param id id
     */
    void messageDead(String id);


}
